<?php
 // 引入 Ratchet 库
namespace app\api\controller;
require root_path().'vendor/autoload.php';

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;

class WebSocket implements MessageComponentInterface {
    public function onOpen(ConnectionInterface $conn) {
        // 连接建立时的处理
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理从前端接收的消息
        // 这里你可以根据你的需求向前端发送数据
        $from->send("你好，前端！");
    }

    public function onClose(ConnectionInterface $conn) {
        // 连接关闭时的处理
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        // 错误处理
    }
}

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new WebSocket()
        )
    ),
    5050 // 指定 WebSocket 服务器的端口
);

$server->run();
